package com.cc.demo.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface ConsumerChannel {

    String INPUT = "intput-01";
    String TRANSACTION_COMPLETED = TransactionChannelConstant.TRANSACTION_COMPLETED;
    String TRANSACTION_FAILED = TransactionChannelConstant.TRANSACTION_FAILED;

    @Input(INPUT)
    SubscribableChannel input();

    @Output(TRANSACTION_COMPLETED)
    MessageChannel completed();

    @Output(TRANSACTION_FAILED)
    MessageChannel failed();


}
